package com.apex.spark.structuredstream;

import com.apex.spark.SparkBaseSource;
import com.apex.spark.SparkEnvironment;
import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;

public interface SparkStructuredStreamingSource extends SparkBaseSource {
    Dataset<Row> getData(SparkEnvironment environment);
}
